package com.duoec.dw.lineage.service.analyser.commend;

import com.duoec.dw.lineage.dto.SqoopCommendArgument;
import org.springframework.stereotype.Service;

/**
 * @author xuwenzhen
 */
@Service
public class QueryCommendLineAnalyser extends BaseCommendLineAnalyser {
    /**
     * 用于检查的起始字段串，如果命中后就会执行
     *
     * @return 起始字段串
     */
    @Override
    public String getStart() {
        return "query ";
    }

    /**
     * 分析
     * query "SELECT	DROP_PARTITION('duoec_trade_center_edw_source.s_du_orders','${dt}')"
     *
     * @param importDto 血缘关系数据
     * @param line      需要处理的行
     */
    @Override
    public void analyse(SqoopCommendArgument importDto, String line) {
        String query = getString("query", line);
        importDto.setQuery(query);
    }
}
